package sggJuc.future;

import java.util.concurrent.ExecutionException;
import java.util.concurrent.FutureTask;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.TimeoutException;

/**
 * Future缺点:
 * 1、get()阻塞: 一旦调用get()方法求结果，如果计算没有完成容易导致程序阻塞
 * 2、isDone()轮询: 轮询的方式会耗费无谓的CPU资源，而且也不见得能及时得到计算结果
 *
 *
 * @author xizheng
 * @date 2023-08-07 22:21:23
 */
public class FutureAPIDemo {
    public static void main(String[] args) throws ExecutionException, InterruptedException, TimeoutException {
        FutureTask<String> futureTask = new FutureTask<String>(() -> {
            System.out.println(Thread.currentThread().getName()+"\t -----come in");
            //暂停几秒钟线程
            try { TimeUnit.SECONDS.sleep(5); } catch (InterruptedException e) { e.printStackTrace(); }
            return "task over";
        });
        Thread t1 = new Thread(futureTask, "t1");
        t1.start();

//        System.out.println(futureTask.get());//会阻塞主线程，一般建议放在程序后面
        System.out.println(Thread.currentThread().getName()+"\t ----忙其它任务了");

//        System.out.println(futureTask.get());
        System.out.println(futureTask.get(3,TimeUnit.SECONDS));

        while(true){
            if(futureTask.isDone()){
                System.out.println(futureTask.get());
                break;
            }else{
                //暂停毫秒
                try { TimeUnit.MILLISECONDS.sleep(500); } catch (InterruptedException e) { e.printStackTrace(); }
                System.out.println("正在处理中，不要再催了，越催越慢 ，再催熄火");
            }
        }
    }
}

/**
 * 1.get容易导致阻塞，一般建议放在程序后面，一旦调用不见不散，非要等到结果才会离开，不管你是否计算完成，容易程序堵塞。
 * 2.假如我不愿意等待很长时间，我希望过时不候，可以自动离开
 */